package main

import "crawler/datasource"

var usersCh = make(chan []string, 20)

func main() {
	//初始化连接池
	pool := datasource.InstanceCache()

	//启动rpc服务
	go bootRpcServer()

	for {
		select {
		case users := <-usersCh:
			go worker(users, pool)
		}
	}
}
